import * as $task from '../services/task'

module.exports = {
  enable: true,
  run: async(job, {taskId}, opts, done) => {
    await $task.publish(taskId)
    done()
  }
}
